package com.too.disruptor;

/**
 * 相当于消费者，获取生产者推送过来的消息
 *
 * @author ouyf
 * @date 2025/9/8 10:18
 * <p>
 * Copyright (c) Siemens Mobility TBDS 2025, All Rights Reserved, Confidential
 */

import com.lmax.disruptor.EventHandler;
public class LongEventHandler implements EventHandler<LongEvent> {


    public void onEvent(LongEvent longEvent, long l, boolean b) throws Exception {
        System.out.println("消费者："+longEvent.getValue());
    }
}
